package com.scorpio.mqtt.config;

import com.scorpio.mqtt.constant.MQConstant;
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/*
 * @author uv
 */
@Configuration
public class ActiveMQConfig {

    //订单过期队列
    @Bean(MQConstant.ORDER_OVERDUE)
    public ActiveMQQueue orderOverdueQueue() {
        return new ActiveMQQueue(MQConstant.ORDER_OVERDUE);
    }

}
